package org.cuasloi.mqtt.controller;

import lombok.extern.log4j.Log4j2;
import org.cuasloi.mqtt.config.MqttGateway;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;


@RestController
@Log4j2
public class SendController {

    @Autowired
    private MqttGateway mqttSend;

    /**
     * 发送自定义消息内容（使用默认主题）
     * @param content 消息内容
     */
    @GetMapping(value = "/send")
    public void test1(String content) {
        log.info("----->{}", "mqtt 消息发布，使用默认主题发布:" + content);
        mqttSend.sendToMqtt(content);
    }

}
